package cn.dataling.dag.listener;

import cn.dataling.dag.pojo.DagWorkflowNode;

import java.util.List;

/**
 * dag节点状态发生变化监听器
 **/
public interface DagNodeStateListener {

    /**
     * 节点状态发生变化
     *
     * @param dagWorkflowNode dag工作流节点
     */
    void onStateChange(DagWorkflowNode dagWorkflowNode);

    /**
     * 节点状态发生变化
     *
     * @param dagWorkflowNodes dag工作流节点集合
     */
    void onStateChange(List<DagWorkflowNode> dagWorkflowNodes);
}
